package com.example.simple;

import org.springframework.amqp.rabbit.annotation.RabbitListener;

/*
 * @className: SimpleConsumer
 * @description 一个生产者,一个队列,一个消费者,这个时候使用的其实是默认的直连交换机（DirectExchange），
 * DirectExchange 的路由策略是将消息队列绑定到一个 DirectExchange 上，
 * 当一条消息到达 DirectExchange 时会被转发到与该条消息 routing key 相同的 Queue 上，
 * 例如消息队列名为 “simple-queue”，则 routingkey 为 “simple-queue” 的消息会被该消息队列接收。
 * @since JDK1.8
 * @author ljh
 * @createdAt  2022/1/19
 * @version 1.0.0
 **/
//@Component
public class SimpleConsumer {
    @RabbitListener(queues = {RabbitConfig.QUEUE_NAME})
    public void reciveMsg(String msg){
        System.out.println("msg3 = " + msg);
    }
}
